package top.jolyoulu.jlmqtt.service;


import org.eclipse.paho.client.mqttv3.MqttMessage;
import top.jolyoulu.jlmqtt.entity.dto.MqttHeartBeatMsgDTO;
import top.jolyoulu.jlmqtt.entity.dto.MqttLastWillMsgDTO;
import top.jolyoulu.jlmqtt.entity.dto.MqttMsgDTO;

public interface MqttSubTopicService {

    /**
     * 收到消息
     * @param topic
     * @param message
     */
    void callBack(String topic, MqttMessage message);

    /**
     * 保存心跳消息
     * @param msgDTO
     */
    void saveHeartBeatInfo(MqttMsgDTO<MqttHeartBeatMsgDTO> msgDTO);
}
